package com.zz.study.sharding.mappers;

import com.zz.study.sharding.entity.DtFusdataFlink;
import com.zz.study.sharding.entity.DtFusdataFlinkSimple;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * created by xjx on  2024-01-31 16:00
 */
@Mapper
public interface CompressTrackDataMapper {

    Long getMaxRecordId(@Param("tableName") String tableName);


    List<DtFusdataFlinkSimple> getRecordByID(@Param("tableName") String tableName,@Param("id") Long id);

//
    List<DtFusdataFlinkSimple> getCompressTrackByMMSIAndTimeSimple(@Param("mmsi") String mmsi,@Param("startTime") Date startTime,@Param("endTime") Date endTime  );

    List<DtFusdataFlinkSimple> getCompressTrackByMMSIAndTimeSimpleSingle(@Param("tableName") String tableName,@Param("mmsi") String mmsi,@Param("startTime") Date startTime,@Param("endTime") Date endTime  );

    List<DtFusdataFlinkSimple> getCompressTrackByMMSISimpleSingle(@Param("tableName") String tableName,@Param("mmsi") String mmsi);


}
